package com.quanyan.mq.client.reqeust;

import java.io.Serializable;
import java.util.Arrays;

/**
 * @Author Hugo.Wwg
 * @Since 2016-06-07
 */
public class MqRequestMsg<T> implements Serializable {

    private int flag;
    private String topic;
    private byte[] body;
    private String tag;
    private String msgId;

    public int getFlag() {
        return flag;
    }

    public void setFlag(int flag) {
        this.flag = flag;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public byte[] getBody() {
        return body;
    }

    public void setBody(byte[] body) {
        this.body = body;
    }

    public String getTag() {
        return tag;
    }

    public void setTag(String tag) {
        this.tag = tag;
    }

    public String getMsgId() {
        return msgId;
    }

    public void setMsgId(String msgId) {
        this.msgId = msgId;
    }

    @Override
    public String toString() {
        return "MqRequestMsg{" +
                "flag=" + flag +
                ", topic='" + topic + '\'' +
                ", body=" + Arrays.toString(body) +
                ", tag='" + tag + '\'' +
                ", msgId='" + msgId + '\'' +
                '}';
    }
}
